package com.cloud.job.config;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * @author 杨斌
 * 2024-12-2024-12-10
 */
@Data
@Component
@ConfigurationProperties(prefix = "kafka")
public class KafkaConfig {
    private String bootstrapServers;
    private List<String> topics;
    private Integer maxPollRecords;
    private Integer maxPollIntervalMs;
    public static final int PARTITIONS_COUNT = 1;
    private String groupId;

}
